package org.example.rabbitmq.consumer.rate;

/**
 * 队列消费限流器
 *
 * 每个队列一个限流器
 */
public interface RateLimiter {
    void acquire(String queueName) throws InterruptedException;

    void release(String queueName);

    void addQueueRateLimiter(String queueName);
}